package com.darcytech.debezium.server;


import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.stereotype.Component;

@Component
@ConfigurationProperties(prefix = "debezium")
public class DebeziumProperties {

    String kafkaServers;

    String kafkaConnectAddresses;

    String zkServers;

    String secret = "000000";

    String rpcAddress;

    public void setKafkaServers(String kafkaServers) {
        this.kafkaServers = kafkaServers;
    }

    public void setKafkaConnectAddresses(String kafkaConnectAddresses) {
        this.kafkaConnectAddresses = kafkaConnectAddresses;
    }

    public String getKafkaServers() {
        return kafkaServers;
    }

    public String getKafkaConnectAddresses() {
        return kafkaConnectAddresses;
    }

    public String getZkServers() {
        return zkServers;
    }

    public void setZkServers(String zkServers) {
        this.zkServers = zkServers;
    }

    public String getSecret() {
        return secret;
    }

    public void setSecret(String secret) {
        this.secret = secret;
    }

    public String getRpcAddress() {
        return rpcAddress;
    }

    public void setRpcAddress(String rpcAddress) {
        this.rpcAddress = rpcAddress;
    }
}
